package com.dabai.iot.mqtt.server.processor;

import com.dabai.common.core.utils.BatchTaskProcessor;
import com.dabai.iot.mqtt.model.MqttMessageContext;
import com.dabai.iot.mqtt.util.MqttMessageUtil;

/**
 * 下行消息处理器
 *
 * @author kev1n
 */
public class MessageToDeviceProcessor extends BatchTaskProcessor<MqttMessageContext> {
    public MessageToDeviceProcessor(MqttMessageUtil mqttMessageUtil) {
        super(mqttMessageUtil::sendMessageToDevice);
    }
}
